package sistema;

import java.util.LinkedList;
import java.util.List;
import java.util.Observable;
import java.util.Observer;

import bus.Bus;

import mensaje.Mensaje;



public class Sistema extends Thread implements Observer {

	private String nombre;
	
	public Sistema(String n) {
		nombre = n;
	}
	
	List<Mensaje> mensajes=new LinkedList<Mensaje>();
	@Override
	public void update(Observable bus, Object msj) {
		this.mensajes.add((Mensaje) msj);
		System.out.println(nombre + " llego el mensaje " + ((Mensaje) msj).getTexto());
		
	}
	
	public void run(){
		
		Bus.getInstance().addObserver(this);
		int x = 0;
		while(true){
			
			
			
			Bus.getInstance().llegoMensaje(new Mensaje(((Integer)x).toString()));

			x++;
			try {
				Thread.sleep(5000);
			} catch (InterruptedException e) {
				System.out.println("");
			}
			
		}
		
		
	}
	
}
